package com.alibaba.datax.elasticresource.watcher;

import org.apache.flink.runtime.leaderelection.LeaderElectionService;
import org.apache.flink.runtime.rpc.FatalErrorHandler;

import com.alibaba.datax.common.util.Configuration;
import com.leehom.arch.rbt.watcher.DataxWatcher;

/**
 * {@link DatxWatcher} factory.
 *
 */
public interface DataxWatcherFactory {

	DataxWatcher createWatcher(
            Configuration configuration,
            LeaderElectionService leaderElectionService, 
            FatalErrorHandler fatalErrorHandler)
            throws Exception;
    
}
